const cloud = require('wx-server-sdk');
cloud.init({
  env: cloud.DYNAMIC_CURRENT_ENV
});
const db = cloud.database()
const _ = db.command
const $ = db.command.aggregate
// 获取openId云函数入口函数
exports.main = async (event, context) => {
  // return await db.collection('collect').aggregate()
  //   .match({
  //     userId: event.userId
  //   })
  //   .lookup({
  //     from: "activity",
  //     localField: 'activityId',
  //     foreignField: '_id',
  //     as: 'sameList'
  //   }).match({
  //     status: event.status,
  //   })
  //   .end({
  //     success: function (res) {
  //       return res;
  //     },
  //     fail(err) {
  //       return err;
  //     }
  //   })
  return await db.collection('collect').aggregate()
    .match({
      userId: event.userId
    })
    .lookup({
      from: "activity",
      let: {
        collect_activityId: "$activityId",
        status: event.status
      },
      pipeline: $.pipeline().match(_.expr($.and([
        $.eq(['$_id', '$$collect_activityId']),
        $.eq(['$status', '$$status'])
      ]))).done(),
      as: 'sameList',
    })
    .end({
      success: function (res) {
        return res;
      },
      fail(err) {
        return err;
      }
    })
  // .end().then(res => console.log(res)).catch(err => console.log(err))
  // return await db.collection('collect').get();
};